package cn.iocoder.yudao.module.call.task;

import cn.hutool.cache.CacheUtil;
import cn.hutool.cache.impl.TimedCache;

public class CallTaskUtil {

    public static final TimedCache<String, Long> TASK_QUEUE = CacheUtil.newTimedCache(1000);

    public static final String KEY = "CALL:TASK:";

    static {

    }

    public static void removeTask(Long taskId) {
        TASK_QUEUE.remove(KEY + taskId);
    }

    /**
     * 启动任务的时候，其实压入一个队列， 并且让他立即执行，然后通过mq通知给callTask消费者
     * callTask 消费者去呼叫指定的名单id
     * @param taskId 任务ID
     * @param callId 呼叫队列id
     * @since 2024-05-17
     * @author PetePower
     */
    public static void addTask(Long taskId, Long callId) {
        TASK_QUEUE.put(KEY + taskId, callId, 1);
    }
}
